import log from '@dfeidao/atom-nodejs/logger/log';
import { IncomingHttpHeaders } from 'http';
import query from '@dfeidao/atom-nodejs/db/query';
import { systemid,productid } from '../../atom/config';

interface Message {
	filter:{
		work_bill_no:string[]

	}
}
// 表名	cust_reask_rec				
// 标题	客户回访记录				
// 字段名称	字段标题	字段类型	字段长度	是否为空	是否主键
// visit_people	回访人	string	50	√	ⅹ
// score	分值	string	50	√	ⅹ
// productid	产品ID	string	50	√	ⅹ
// visit_phone	回访人电话	string	50	√	ⅹ
// revisit_days	回访时间	timestamp	50	√	ⅹ
// work_bill_no	工单编号	string	50	√	ⅹ
// visit_result	回访结果	string	50	√	ⅹ
// record_no	记录编号	string	50	√	ⅹ
// cust_sat	客户满意度	int	50	ⅹ	ⅹ
// _id	id	string	50	ⅹ	√

export default async function atom(message: Message, action_id: string, session_id: string, headers: IncomingHttpHeaders){
	const  p= query(action_id,session_id,systemid);
	p.prepare('cust_reask_rec', ['work_bill_no','revisit_days','cust_sat'], { productid,work_bill_no:{$in:message.filter.work_bill_no}}
	, 20, 1, [], []);
	p.prepare('cust_reask_rec', ['cust_sat'], { productid,work_bill_no:{$in:message.filter.work_bill_no}}
	, 20, 1, [], []);
	const [dt1,dt2] = await p.exec();
	return {dt1,dt2};
}
